<?php
/**
 * Created by PhpStorm.
 * User: zhangjincheng
 * Date: 17-9-7
 * Time: 上午10:35
 */

namespace app\AMQPTasks;

use Server\Components\AMQPTaskSystem\AMQPTask;
use Celery;


class WsdAMQPTask extends AMQPTask
{
    /**
     * handle
     * @param $body
     */
    public function handle($body)
    {
        //var_dump($body);
        $msg = json_decode($body);
        //echo "method=".$msg->method."\n";
        //echo "\nkwargs=".$msg['kwargs'];
        echo "============\nworker_id=".$this->server->worker_id.", ".$msg->id."\n";
        $this->ack();
    }
}